package top.fullj.actor.mq;

public interface Channel<T> extends Subscriber<T>, Publisher<T> {

    void clearSubscribers();

}
